package com.gujiangbo.disruptor;

import com.lmax.disruptor.EventHandler;

/**
 * 消费者  --定义事件的具体实现
 */
public class StringEventHandler implements EventHandler<StringEvent> {


    //具体的业务处理场景
    @Override
    public void onEvent(StringEvent event, long sequeue, boolean endOfBatch) throws Exception {
        System.out.println("消费者:" + event.getValue() +
                "sequeue=" + sequeue + ",endOfBatch=" + endOfBatch);
    }
}
